//package test.elasticjob;
//
//import com.dangdang.ddframe.job.api.JobConfiguration;
//import com.dangdang.ddframe.job.api.JobScheduler;
//import com.dangdang.ddframe.reg.base.CoordinatorRegistryCenter;
//import com.dangdang.ddframe.reg.zookeeper.ZookeeperConfiguration;
//import com.dangdang.ddframe.reg.zookeeper.ZookeeperRegistryCenter;
//
//public class App {
//	
//	// 定义Zookeeper注册中心配置对象
//    private ZookeeperConfiguration zkConfig = new ZookeeperConfiguration("localhost:2181", "elastic-job-example", 1000, 3000, 3);
//
//    // 定义Zookeeper注册中心
//    private CoordinatorRegistryCenter regCenter = new ZookeeperRegistryCenter(zkConfig);
//
//    // 定义作业1配置对象
//    private JobConfiguration jobConfig1 = new JobConfiguration("simpleJob", SimpleJobDemo.class, 10, "0/5 * * * * ?");
//
//    // 定义作业2配置对象
////    private JobConfiguration jobConfig2 = new JobConfiguration("throughputDataFlowJob", ThroughputDataFlowJobDemo.class, 10, "0/5 * * * * ?");
//
//    // 定义作业3配置对象
////    private JobConfiguration jobConfig3 = new JobConfiguration("sequenceDataFlowJob", SequenceDataFlowJobDemo.class, 10, "0/5 * * * * ?");
//
//    public static void main(final String[] args) {
//        new App().init();
//    }
//
//    private void init() {
//        // 连接注册中心
//        regCenter.init();
//        // 启动作业1
//        new JobScheduler(regCenter, jobConfig1).init();
//        // 启动作业2
////        new JobScheduler(regCenter, jobConfig2).init();
//        // 启动作业3
////        new JobScheduler(regCenter, jobConfig3).init();
//    }
//
//}
